#!/usr/bin/env python
# encoding: utf-8
# @author: Lin Han
# @contact: voldemort22@126.com
# @file: update_02_format_20210602.py
# @time: 2021/6/2 17:44
# @desc:
from .utils.mongo_tools import retrieve_all_mongo_values
from .views.configs import HISTORY_PART_COLLECTION
from .views.crud import send_to_message_queue

history_parts = retrieve_all_mongo_values({}, collection_name=HISTORY_PART_COLLECTION)

for i in history_parts:
    send_to_message_queue(i["number"])